<?php
//   +----------------------------------------------------------------------
//   | Copyright (c) 2015-2025 http://www.hdphp.cn All rights reserved.
//   | Licensed ( http://www.hdphp.cn/licenses/ )
//   | Author: Jack <sophia2152@qq.com>
//   | 官方网址: http://www.hdphp.cn
//   | 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和使用。
//   | 任何企业和个人不允许对程序代码以任何形式任何目的再发布。
//   +----------------------------------------------------------------------
namespace hdphp\utils;

use think\swoole\Manager;
use Swoole\Timer;
use think\facade\Log;

/**
 * Class：Cron定时执行
 * 创建人：Jack
 * 创建时间：2024/1/11 11:44
 * @package hdphp\utils
 */
class Cron
{
    /**
     * @var Manager
     */
    protected $manager;

    /**
     * @var int
     */
    protected $workerId = 0;

    /**
     * @var
     */
    protected $timer;

    /**
     * @var bool
     */
    protected $debug = false;

    /**
     * 构造函数
     * @param Manager $manager
     */
    public function __construct(Manager $manager)
    {
        $this->manager = $manager;
        $this->debug = env('APP_DEBUG', false);

    }

    /**
     * 注释：setWorkerId
     * 创建人：Jack
     * 创建时间：2024/1/11 11:45
     * @param int $workerId
     * @return $this
     */
    public function setWorkerId(int $workerId)
    {
        $this->workerId = $workerId;
        return $this;
    }

    /**
     * 注释：沙盒运行
     * 创建人：Jack
     * 创建时间：2024/1/11 11:45
     * @param callable $callable
     * @return void
     */
    protected function runInSandbox(callable $callable)
    {
        $this->manager->runWithBarrier([$this->manager, 'runInSandbox'], function () use ($callable) {
            try {
                $callable();
            } catch (\Throwable $e) {
                $this->debug && Log::error($e->getMessage());
            }
        });
    }

    /**
     * 注释：添加启动定时任务
     * 创建人：Jack
     * 创建时间：2024/1/11 11:45
     * @param int      $ms
     * @param callable $callable
     * @return int|null
     */
    public function tick(int $ms, callable $callable)
    {
        if ($this->workerId === $this->manager->getWorkerId()) {
            return Timer::tick($ms, function () use ($callable) {
                $this->runInSandbox($callable);
            });
        } else {
            return null;
        }
    }

    /**
     * 注释：每天的某时某分运行一次
     * minuteTick('12:15',fun()) 例如: 12:15 会在当天的中午12点15分钟运行一次
     * 创建人：Jack
     * 创建时间：2024/1/11 11:45
     * @param string   $time
     * @param callable $callable
     * @return int|null
     */
    public function minuteTick(string $time, callable $callable)
    {
        return $this->tick(1000 * 60, function () use ($callable, $time) {
            $nowTime = date('H:i');
            if ($nowTime === $time) {
                $callable();
            }
        });
    }

    /**
     * 注释：一次执行
     * 创建人：Jack
     * 创建时间：2024/1/11 11:46
     * @param int      $ms
     * @param callable $callable
     * @return void
     */
    public function after(int $ms, callable $callable)
    {
//        if ($this->workerId === $this->manager->getWorkerId()) {
        Timer::after($ms, function () use ($callable) {
            $this->runInSandbox($callable);
        });
//        }
    }

    /**
     * 注释：清除定时任务
     * 创建人：Jack
     * 创建时间：2024/1/11 11:46
     * @param int $timer
     * @return void
     */
    public function clear(int $timer)
    {
        Timer::clear($timer);
    }

    /**
     * 注释：清除所有定时任务
     * 创建人：Jack
     * 创建时间：2024/1/11 11:46
     * @return void
     */
    public function clearAll()
    {
        Timer::clearAll();
    }
}
